package com.ying.cube;

import com.pylc.cube.common.sync.SyncUser;
import com.pylc.cube.sync.consumer.processor.UserSyncProcessor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.util.List;

@Component
@Slf4j
public class TestUserSyncProcessor implements UserSyncProcessor {

    @Override
    public void onAdd(List<SyncUser> user) {
        // 新增的用户信息会在这里出现
        System.out.println( user);
    }

    @Override
    public void onUpdate(List<SyncUser> user) {
        // 修改的用户信息会在这里出现
        System.out.println( user);
    }

    @Override
    public void onDelete(List<String> user) {
        // 被删除的用户信息会在这里出现，这里只有工号
        System.out.println( user);
    }
}
